package cn.yto.rocketmq.rocketmqselect.service;

import cn.yto.rocketmq.rocketmqselect.model.MessageView;
import org.apache.rocketmq.common.Pair;
import org.apache.rocketmq.common.message.MessageExt;
import org.apache.rocketmq.tools.admin.api.MessageTrack;

import java.util.List;

public interface MessageService {


    Pair<MessageView, List<MessageTrack>> viewMessage(String subject, final String msgId);


    List<MessageTrack> messageTrackDetail(MessageExt msg);

    List<MessageView> queryMessageByTopicAndKey(final String topic, final String key);


    List<MessageView> queryMessageByTopic(final String topic, final long begin,
                                          final long end);

}
